﻿using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using radnaVerzija.Interfejsi;
using MySql.Data.MySqlClient;

namespace radnaVerzija
{

    public partial class DAL{
    public class SportskoDrustvoDAO
    {
         protected MySqlCommand komanda;

            public long create(SportskoDrustvo entitet)
            {
                try
                {
                    komanda = new MySqlCommand("insert SportskaDrustva values ('" +
                        entitet.IdUgovora.ToString() + "', '" + entitet.ImeDrustva + "', '" +
                        entitet.MaxBrojClanova.ToString() +
                        entitet.Trener.Ime + "', '" + entitet.Trener.Prezime  +
                        ";", konekcija);
                    komanda.ExecuteNonQuery();
                    return komanda.LastInsertedId;
                }
                catch (Exception ex)
                {
                    throw ex;
                }
            }

            public SportskoDrustvo read(SportskoDrustvo entitet)
            {
                try
                {
                    komanda = new MySqlCommand("select * from SportskaDrustva where sd_ID = '" + entitet.IdSD.ToString() + "';", konekcija);
                    MySqlDataReader citac = komanda.ExecuteReader();
                    SportskoDrustvo sd = null;
                    while (citac.Read())
                    {
                       
                        sd = new SportskoDrustvo(citac.GetString("ime"));
                        return sd;
                    }
                    return sd;
                }
                catch (Exception ex)
                {
                    throw ex;
                }
            }

            public SportskoDrustvo update(SportskoDrustvo entitet)
            {
                try
                {
                    komanda = new MySqlCommand("update SportskaDrustva set ime = '" + entitet.ImeDrustva +
                        "', id_ugovora ='" + entitet.IdUgovora.ToString() +
                        "', brojclanova =" + entitet.MaxBrojClanova.ToString()+
                        "', trener = '" + (entitet.Trener.Ime+" "+ entitet.Trener.Prezime)+
                        " where sd_ID = " + entitet.IdSD, konekcija);
                    komanda.ExecuteNonQuery();
                    return read(entitet);
                }
                catch (Exception ex)
                {
                    throw ex;
                }
            }

            public void delete(SportskoDrustvo entitet)
            {
                try
                {
                    komanda = new MySqlCommand("delete from SportskaDrustva where sd_ID = " + entitet.IdSD + ";", konekcija);
                    komanda.ExecuteNonQuery();
                }
                catch (Exception ex)
                {
                    throw ex;
                }
            }
        }
    }
    }

